package p270jp.pxv.android.legacy.muteSetting.flux;

import android.annotation.SuppressLint;
import androidx.lifecycle.AbstractC0720j0;
import androidx.lifecycle.LiveData;
import androidx.lifecycle.MutableLiveData;
import p014ae.C0180w6;
import p071cd.Functions;
import p325m0.MutabilityOwnership;
import p445qf.C5830a;
import p493sf.AbstractC6047g;
import p599wi.MuteSettingEvent;
import p671zc.CompositeDisposable;

/* compiled from: MuteSettingStore.kt */
@SuppressLint({"RxJava2SubscribeMissingOnError"})
/* renamed from: jp.pxv.android.legacy.muteSetting.flux.MuteSettingStore */
/* loaded from: classes2.dex */
public final class MuteSettingStore extends AbstractC0720j0 {

    /* renamed from: c */
    public final CompositeDisposable f19084c;

    /* renamed from: d */
    public final MutableLiveData<C5830a<MuteSettingEvent>> f19085d;

    /* renamed from: e */
    public final LiveData<C5830a<MuteSettingEvent>> f19086e;

    public MuteSettingStore(AbstractC6047g gVar) {
        MutabilityOwnership.m3745m(gVar, "readOnlyDispatcher");
        CompositeDisposable aVar = new CompositeDisposable();
        this.f19084c = aVar;
        MutableLiveData<C5830a<MuteSettingEvent>> xVar = new MutableLiveData<>();
        this.f19085d = xVar;
        this.f19086e = xVar;
        aVar.mo82c(gVar.mo2435a().m984q(new C0180w6(this, 6), Functions.f5388e, Functions.f5386c, Functions.f5387d));
    }

    @Override // androidx.lifecycle.AbstractC0720j0
    /* renamed from: b */
    public void mo315b() {
        this.f19084c.m80f();
    }
}
